package top.javatool.canal.client.spring.boot.properties;

import lombok.Data;
import org.apache.commons.lang.StringUtils;

import java.util.concurrent.TimeUnit;

/**
 * @author yang peng
 * @date 2019/4/1915:19
 */
@Data
public class CanalProperties {
    public static final String CANAL_PREFIX = "canal";
    public static final String CANAL_ASYNC = CANAL_PREFIX + "." + "async";
    public static final String CANAL_MODE = CANAL_PREFIX + "." + "mode";

    /**
     * simple,cluster,zookeeper,kafka,rocketMQ
     */
    private String mode;
    private Boolean async;
    private String server;
    private String destination;
    private String filter = StringUtils.EMPTY;
    private Integer batchSize = 1;
    private Long timeout = 1L;
    private TimeUnit unit = TimeUnit.SECONDS;
}
